bitkeeper revision 1.1050 (40ed36c3QPnXaALAJYdfejK34cJfFA)

Fix problem with message ids.

diff --git a/tools/python/xen/xend/server/messages.py b/tools/python/xen/xend/server/messages.py
index edda5f2303b5a373879e548b83c142945bb481af..92b26091b28f589991534b2e0f4f420e38d280cf 100644 (file)
--- a/tools/python/xen/xend/server/messages.py
+++ b/tools/python/xen/xend/server/messages.py
@@ -1,3 +1,4 @@
+import sys
 import struct
 
 from xen.lowlevel import xu
@@ -182,17 +183,25 @@ class Msg:
 _next_msgid = 0
 
 def nextid():
+    """Generate the next message id.
+
+    @return: message id
+    @rtype: int
+    """
     global _next_msgid
-    return ++_next_msgid
+    _next_msgid += 1
+    return _next_msgid
 
 def packMsg(ty, params):
     """Pack a message.
-    Any 'mac' parameter is passed in as an int[6] array and converted.
-
-    ty     message type name
-    params message parameter dict
-
-    returns xu message
+    Any I{mac} parameter is passed in as an int[6] array and converted.
+
+    @param ty: message type name
+    @type ty: string
+    @param params: message parameters
+    @type params: dicy
+    @return: message
+    @rtype: xu message
     """
     msgid = nextid()
     if DEBUG: print '>packMsg', msgid, ty, params
@@ -208,6 +217,7 @@ def packMsg(ty, params):
         for (k, v) in args.items():
             print 'packMsg>', k, v, type(v)
     msg = xu.message(major, minor, msgid, args)
+    if DEBUG: print '<packMsg', msg.get_header()['id'], ty, params
     return msg
 
 def unpackMsg(ty, msg):
@@ -215,10 +225,12 @@ def unpackMsg(ty, msg):
     Any mac addresses in the message are converted to int[6] array
     in the return dict.
 
-    ty  message type
-    msg xu message
-
-    returns parameter dict
+    @param ty:  message type
+    @type ty: string
+    @param msg: message
+    @type msg: xu message
+    @return: parameters
+    @rtype: dict
     """
     args = msg.get_payload()
     mac = [0, 0, 0, 0, 0, 0]
@@ -240,15 +252,36 @@ def unpackMsg(ty, msg):
     return args
 
 def msgTypeName(ty, subty):
-    """Convert a message type, subtype pair (ints) to a message type name (string).
-
-    ty    integer message type
-    subty integer message subtype
-
-    returns message type name (or None)
+    """Convert a message type, subtype pair to a message type name.
+
+    @param ty: message type
+    @type ty: int
+    @param subty: message subtype
+    @type ty: int
+    @return: message type name (or None)
+    @rtype: string or None
     """
     for (name, info) in msg_formats.items():
         if info[0] == ty and info[1] == subty:
             return name
     return None
 
+def printMsg(msg, out=sys.stdout, all=0):
+    """Print a message.
+
+    @param msg: message
+    @type msg: xu message
+    @param out: where to print to
+    @type out: stream
+    @param all: print payload if true
+    @type all: bool
+    """
+    hdr = msg.get_header()
+    major = hdr['type']
+    minor = hdr['subtype']
+    msgid = hdr['id']
+    ty = msgTypeName(major, minor)
+    print >>out, 'message:', 'type=', ty, '%d:%d' % (major, minor), 'id=%d' % msgid
+    if all:
+        print >>out, 'payload=', unpackMsg(ty, msg)
+